//订阅者回调签名
// ignore_for_file: prefer_generic_function_type_aliases
typedef void EventCallback(arg);

enum Event {
  updateBottomTabIndex,
  updateBottomTabUnread,
}

class EventBus {
  //私有构造函数
  EventBus._internal();

  //保存单例
  static final EventBus _singleton = EventBus._internal();

  //工厂构造函数
  factory EventBus() => _singleton;

  //保存事件订阅者队列，key:事件名(id)，value: 对应事件的订阅者队列
  final _emap = <Object, List<EventCallback>>{};

  //保存最后一次的数据
  final _data = <Object, dynamic>{};

  //添加订阅者
  void on(eventName, EventCallback f) {
    if (eventName == null || f == null) return;
    _emap[eventName] ??= <EventCallback>[];
    _emap[eventName]!.add(f);
  }

  //添加订阅者, 并且会接受到上一次触发的事件
  void listen(eventName, EventCallback f) {
    on(eventName, f);
    if (_data.containsKey(eventName)) f(_data[eventName]);
  }

  //移除订阅者
  void off(eventName, [EventCallback? f]) {
    if (eventName == null) return;
    if (f == null) {
      _emap.remove(eventName);
      _data.remove(eventName);
    } else {
      var list = _emap[eventName] ?? [];
      list.remove(f);
      if (list.isEmpty) _data.remove(eventName);
    }
  }

  //触发事件，事件触发后该事件所有订阅者会被调用
  void emit(eventName, [arg]) {
    _data[eventName] = arg;
    var list = _emap[eventName];
    if (list == null) return;
    var len = list.length - 1;
    //反向遍历，防止订阅者在回调中移除自身带来的下标错位
    for (var i = len; i > -1; --i) {
      try {
        list[i](arg);
      } catch (e) {
        print(e);
      }
    }
  }
}

//定义一个top-level（全局）变量，页面引入该文件后可以直接使用bus
var bus = EventBus();
